package com.cnsdhh.javajms.queue;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class QueueProducer {

    public static void main(String[] args) throws JMSException {
        //1.创建连接工厂对象（需要中间件连接地址：tcp://192.168.25.153:61616）
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.153:61616");
        //2.使用连接工厂创建连接
        Connection connection = connectionFactory.createConnection();
        //3.启动连接
        connection.start();

        //4.使用连接创建会话（参数1：是否启动事务  参数2：消息确认方式）
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //5.使用会话创建消息队列
        Queue queue = session.createQueue("test-queue");

        //6.使用会话创建生产者（需要消息队列：queue）
        MessageProducer producer = session.createProducer(queue);
        //7.使用会话创建消息
        TextMessage textMessage = session.createTextMessage("java JMS for ActiveMQ : queue(点对点)");
        //8.使用生产者发送消息到中间件服务器：ActiveMQ
        producer.send(textMessage);

        //9.关闭连接资源
        producer.close();
        session.close();
        connection.close();
    }
}
